f4f5157ab6579fea149fe633e44b5b878c187d3f,jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java,CompressExtension,decompress,#number[]#,132

Before Change


            while (decompressor.getRemaining() > 0 && !decompressor.finished())
            {
                byte[] output = new byte[Math.min(input.length * 2, 32 * 1024)];
                int decompressed = decompressor.inflate(output);
                if (decompressed == 0)
                {
                    if (decompressor.needsInput())

After Change


    protected void decompress(ByteAccumulator accumulator, ByteBuffer buf)
    throws DataFormatException
    {
        if ((buf == null) || (!buf.hasRemaining()))
        {
            return;
        }
        byte[] output = new byte[1024];

        if (inflater.needsInput() && !supplyInput(inflater, buf))
        {
            LOG.debug("Needed input, but no buffer could supply input");
            return;
        }

        int read = 0;
        while ((read = inflater.inflate(output)) >= 0)
        {
            if (read == 0)
            {